package com.yuan.stream流复习;

import reactor.core.publisher.Flux;

import java.time.Duration;
import java.util.function.BiConsumer;

/*
 *  @author 雨安
 *  类名： StreamDemo1
 *  创建时间：2024/5/14
 */
public class StreamDemo1 {

    public static void main(String[] args) {
        Flux<Integer> just = Flux.just(1, 2, 3, 4, 5);

        just.subscribe(e-> System.out.println(e));

    }

}
